package com.test.mq;

import org.apache.rocketmq.common.message.MessageExt;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class CancelOrderProcessor implements IMessageProcessor{
    public static final Logger  LOGGER=LoggerFactory.getLogger(CancelOrderProcessor.class);
	
	public boolean handleMessage(MessageExt messageExt) {
		try {
			String body=new String (messageExt.getBody(),"UTF-8");
		    String msgId=messageExt.getMsgId();
		    String tags=messageExt.getTags();
		    String keys=messageExt.getKeys();
		    LOGGER.info("user CancelOrderProcessor receive message:"+messageExt);
		    System.out.println(body);
		    return true;
		} catch (Exception e) {
			return false;
		}
		
	}

}
